package dao;

import java.sql.Connection;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

import com.mysql.jdbc.CallableStatement;

import utils.MySqlDBConexion;


import bean.PeliculaDTO;
import interfaces.PeliculaDAO;

public class MySqlPeliculaDAO implements PeliculaDAO {

	@Override
	public List<PeliculaDTO> listadoDePeliculas() {
		List<PeliculaDTO> lista = new ArrayList<PeliculaDTO>();
		
		Connection cn= MySqlDBConexion.getConexion();
		try {			
			String sql="CALL LISTAR_PELICULA();";
			CallableStatement cs = (CallableStatement) cn.prepareCall(sql);			
			ResultSet rs=cs.executeQuery();
			
			
			while (rs.next()) {
				PeliculaDTO pelicula=new PeliculaDTO(rs.getString(1), rs.getString(2), rs.getString(3), 	rs.getInt(4));
				lista.add(pelicula);
			}
			cn.close();
		} catch (Exception e) {
		e.printStackTrace();
		}
		return lista;
	}

}
